package com.flink.cus.winfun;

import org.apache.flink.api.common.functions.ReduceFunction;
import org.apache.flink.api.java.tuple.Tuple3;

public class MyReduceSum implements ReduceFunction<Tuple3<Long, Float, Long>>{

    @Override
    public Tuple3<Long, Float, Long> reduce(Tuple3<Long, Float, Long> v1, Tuple3<Long, Float, Long> v2)
            throws Exception {
        return new Tuple3<Long, Float, Long>(v1.f0, v1.f1 + v2.f1, v1.f2);
    }

}
